package com.hy.study.reduce;

import com.hy.study.bean.SortFlowBean;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;

import java.io.IOException;

/**
 * reducer阶段 输入key 可以排序的bean 输入value:手机号 输出key 手机号 输出value 可以排序的bean
 *
 * @author huyong
 * @date 2024 年 02 月 05 日 15:26: 55
 */
public class SortFlowCountReducer extends Reducer<SortFlowBean, Text, Text, SortFlowBean> {
    @Override
    protected void reduce(SortFlowBean key, Iterable<Text> values, Reducer<SortFlowBean, Text, Text, SortFlowBean>.Context context) throws IOException, InterruptedException {
        for (Text value : values) {
            context.write(value, key);
        }
    }
}
